const mysql = require('mysql');
module.exports = {
    // 数据库配置
    config: {
        host: "localhost",
        port: "3306",
        user: "root",
        password: "48625",
        database: "blog"
    },
    // 连接数据库，使用连接池的方式
    // 连接池对象
    sqlConnect: function (sql, sqlArr, callback) {


    },
    // promise回调
    SySqlConnect(sySql, sqlArr) {
        return new Promise((resolve, reject) => {
            var pool = mysql.createPool(this.config);
            pool.getConnection((err, conn) => {
                console.log("数据库连接池");
                if (err) {
                    reject(err)
                } else {
                    // 事件驱动回调
                    conn.query(sySql, sqlArr,(err,data)=>{
                        if(err){
                            reject(err)
                        }else{
                            resolve(data)
                        }
                    });
                    // 释放连接
                    conn.release();
                }

            })
        }).catch((err)=>{
            console.log(err)
        })
    }
}